package kafka

import (
	"github.com/Shopify/sarama"
	"github.com/bitly/go-simplejson"
	"go.uber.org/zap"
)

type Kafkaer struct {
	caAdmin      sarama.ClusterAdmin
	body         *simplejson.Json
	broker       []*sarama.Broker
	brokerList   []string
	controllerID int32
	topicDetail  map[string]sarama.TopicDetail
	result       []interface{}
	client       sarama.Client
	cg           ConsumerGroups
}

type ConsumerGroups struct {
	startOffset       bool
	version           string
	ready             chan bool
	group             string
	channelBufferSize int
	assignor          string
	client            sarama.ConsumerGroup
	startTime         string
}

var (
	ZapLog *zap.Logger
)
var CAKafkaer = &Kafkaer{}
